package com.example.mq.common;

import com.example.mq.mqServer.core.message.BasicProperties;
import com.example.mq.mqServer.exception.MqException;

@FunctionalInterface
public interface Consumer {
    //虚拟机通过此方法将消息推送给对应消费者
    void  handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] data);
}
